package com.itlong.cloud.commons.thread.queue.process.queue;

import com.itlong.cloud.POJO.PO.SendCallElevatorMessageTaskPO;
import org.springframework.stereotype.Component;

import java.util.concurrent.DelayQueue;

/**
 * <desc>
 *      发送呼梯消息至iot中心自定义队列
 * </desc>
 *
 * @createDate 2018/04/12
 */
@Component
public class SendIotCallElevatorQueue {
    //发送呼梯消息至iot中心延迟队列
    //处理的代码位于service-equip\src\main\java\com\itlong\cloud\commons\thread\queue\process\consumer\SendCallElevatorMessageConsumer.java
    private DelayQueue<SendCallElevatorMessageTaskPO> sendIotCallElevatorQueue = new DelayQueue();

    public DelayQueue<SendCallElevatorMessageTaskPO> getSendIotCallElevatorQueue() {
        return sendIotCallElevatorQueue;
    }
}
